629923bf0288f381a6d89b8249ce0e081333e3e9,software/nosql/src/main/java/brooklyn/entity/nosql/riak/RiakClusterImpl.java,RiakClusterImpl,onServerPoolMemberChanged,#Entity#,102
Before Change
log.error("Unable to get riak name for node: {}", member.getId());
} else {
//flag a first node to be the first node in the riak cluster.
if (!isFirstNodeSet.get()) {
nodes.put(member, riakName);
setAttribute(RIAK_CLUSTER_NODES, nodes);
((EntityInternal) member).setAttribute(RiakNode.RIAK_NODE_HAS_JOINED_CLUSTER, Boolean.TRUE);
isFirstNodeSet.set(true);
log.info("Adding riak node {}: {}; {} to cluster", new Object[]{this, member, getRiakName(member)});
After Change
Preconditions.checkNotNull(riakName);
// flag a first node to be the first node in the riak cluster.
if (!isFirstNodeSet.getAndSet(true)) {
nodes.put(member, riakName);
setAttribute(RIAK_CLUSTER_NODES, nodes);